package com.example.user.listener;

import com.exmaple.cdc.annotation.CDCListener;
import com.exmaple.cdc.listener.CDCMessageListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Map;

/**
 * @author chentao
 * @version 1.0
 * @description: TODO
 * @date 2025/3/15 下午2:40
 */
@CDCListener(tableName = "sys_user_register_fee_message", multiple = false)
public class SysUserRegisterFeeListener implements CDCMessageListener {

    Logger logger = LoggerFactory.getLogger(getClass());

    /***
     * 实时消息处理
     * @param binlogObj
     */
    @Override
    public void onMessage(Object binlogObj) throws Exception {
        logger.warn("server receive: " + binlogObj);
    }

    /**
     * 补偿消息处理
     *
     * @param map
     */
    @Override
    public void failHandler(Map<String, Object> map) throws Exception {

    }
}
